#! /bin/bash
# 定义一个数组来存储节点ID
declare -a node_ids=(node101 node102 node103)
opt=$1
shift
new_node_ids=("$@")
# 遍历传入的节点ID
for node_id in "${new_node_ids[@]}"; do
    # 检查节点ID是否已经在数组中
    if [[ ! "${node_ids[*]}" =~ ${node_id} ]]; then
        # 如果不在数组中，则添加
        node_ids+=("$node_id")
    fi
done

case $opt in
"start"){
    for i in "${node_ids[@]}"
    do
        echo " --------启动 $i Kafka-------"
        ssh $i "$KAFKA_HOME/bin/kafka-server-start.sh -daemon $KAFKA_HOME/config/server.properties"
    done
};;
"stop"){
    for i in "${node_ids[@]}"
    do
        echo " --------停止 $i Kafka-------"
        ssh $i "$KAFKA_HOME/bin/kafka-server-stop.sh "
    done
};;
esac

